package com.sp.system.user.core.customer.impl;

import com.sp.system.user.core.customer.ITopicCustomer;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class TopicCustomerImpl implements ITopicCustomer {

    @Override
    @JmsListener(destination = "sp_topic", containerFactory = "jmsListenerContainerTopic")
    public void receiveStringTopic(String msg) throws Exception {
        System.out.println("接收到主题A...." + msg);
    }
}
